package com.zhuwei.kafka.config;

import com.zhuwei.kafka.constant.Topic;
//import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;


/**
 * 功能；kafka配置类，如果未手动创建topic，可以启用此配置在项目启动时创建topic
 * @author zhuwei
 * @version 2019/05/14
 */
//@Configuration
public class KafkaConfig {

//    @Bean
//    public NewTopic groupTopic() {
//        // 指定主题名称，分区数量，副本数
//        return new NewTopic(Topic.GROUP, 1, (short) 1);
//    }
}
